home *** CD-ROM | disk | FTP | other *** search
/ Total Network Tools 2002 / NextStepPublishing-TotalNetworkTools2002-Win95.iso / Archive / Misc Servers / Zope.exe / DAVCMDS.PY < prev    next >
Encoding:
Python Source  |  2000-05-26  |  14.4 KB  |  357 lines
  1. ##############################################################################
  2. # 
  3. # Zope Public License (ZPL) Version 1.0
  4. # -------------------------------------
  5. # 
  6. # Copyright (c) Digital Creations.  All rights reserved.
  7. # 
  8. # This license has been certified as Open Source(tm).
  9. # 
  10. # Redistribution and use in source and binary forms, with or without
  11. # modification, are permitted provided that the following conditions are
  12. # met:
  13. # 
  14. # 1. Redistributions in source code must retain the above copyright
  15. #    notice, this list of conditions, and the following disclaimer.
  16. # 
  17. # 2. Redistributions in binary form must reproduce the above copyright
  18. #    notice, this list of conditions, and the following disclaimer in
  19. #    the documentation and/or other materials provided with the
  20. #    distribution.
  21. # 
  22. # 3. Digital Creations requests that attribution be given to Zope
  23. #    in any manner possible. Zope includes a "Powered by Zope"
  24. #    button that is installed by default. While it is not a license
  25. #    violation to remove this button, it is requested that the
  26. #    attribution remain. A significant investment has been put
  27. #    into Zope, and this effort will continue if the Zope community
  28. #    continues to grow. This is one way to assure that growth.
  29. # 
  30. # 4. All advertising materials and documentation mentioning
  31. #    features derived from or use of this software must display
  32. #    the following acknowledgement:
  33. # 
  34. #      "This product includes software developed by Digital Creations
  35. #      for use in the Z Object Publishing Environment
  36. #      (http://www.zope.org/)."
  37. # 
  38. #    In the event that the product being advertised includes an
  39. #    intact Zope distribution (with copyright and license included)
  40. #    then this clause is waived.
  41. # 
  42. # 5. Names associated with Zope or Digital Creations must not be used to
  43. #    endorse or promote products derived from this software without
  44. #    prior written permission from Digital Creations.
  45. # 
  46. # 6. Modified redistributions of any form whatsoever must retain
  47. #    the following acknowledgment:
  48. # 
  49. #      "This product includes software developed by Digital Creations
  50. #      for use in the Z Object Publishing Environment
  51. #      (http://www.zope.org/)."
  52. # 
  53. #    Intact (re-)distributions of any official Zope release do not
  54. #    require an external acknowledgement.
  55. # 
  56. # 7. Modifications are encouraged but must be packaged separately as
  57. #    patches to official Zope releases.  Distributions that do not
  58. #    clearly separate the patches from the original work must be clearly
  59. #    labeled as unofficial distributions.  Modifications which do not
  60. #    carry the name Zope may be packaged in any form, as long as they
  61. #    conform to all of the clauses above.
  62. # 
  63. # 
  64. # Disclaimer
  65. # 
  66. #   THIS SOFTWARE IS PROVIDED BY DIGITAL CREATIONS ``AS IS'' AND ANY
  67. #   EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  68. #   IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  69. #   PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL DIGITAL CREATIONS OR ITS
  70. #   CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  71. #   SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  72. #   LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
  73. #   USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  74. #   ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  75. #   OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
  76. #   OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  77. #   SUCH DAMAGE.
  78. # 
  79. # 
  80. # This software consists of contributions made by Digital Creations and
  81. # many individuals on behalf of Digital Creations.  Specific
  82. # attributions are listed in the accompanying credits file.
  83. # 
  84. ##############################################################################
  85.  
  86. """WebDAV xml request objects."""
  87.  
  88. __version__='$Revision: 1.8 $'[11:-2]
  89.  
  90. import sys, os, string, regex
  91. from common import absattr, aq_base, urlfix, urlbase
  92. from OFS.PropertySheets import DAVProperties
  93. from xmltools import XmlParser
  94. from cStringIO import StringIO
  95. from urllib import quote
  96.  
  97.  
  98. class DAVProps(DAVProperties):
  99.     """Emulate required DAV properties for objects which do
  100.        not themselves support properties. This is mainly so
  101.        that non-PropertyManagers can appear to support DAV
  102.        PROPFIND requests."""
  103.     def __init__(self, obj):
  104.         self.__obj__=obj
  105.     def v_self(self):
  106.         return self.__obj__
  107.     p_self=v_self
  108.  
  109.  
  110.  
  111. class PropFind:
  112.     """Model a PROPFIND request."""
  113.     def __init__(self, request):
  114.         self.request=request
  115.         self.depth='infinity'
  116.         self.allprop=0
  117.         self.propname=0
  118.         self.propnames=[]
  119.         self.parse(request)
  120.         
  121.     def parse(self, request, dav='DAV:'):
  122.         self.depth=request.get_header('Depth', 'infinity')
  123.         if not (self.depth in ('0','1','infinity')):
  124.             raise 'Bad Request', 'Invalid Depth header.'
  125.         body=request.get('BODY', '')
  126.         self.allprop=(not len(body))
  127.         if not body: return
  128.         try:    root=XmlParser().parse(body)
  129.         except: raise 'Bad Request', sys.exc_info()[1]
  130.         e=root.elements('propfind', ns=dav)
  131.         if not e: raise 'Bad Request', 'Invalid xml request.'
  132.         e=e[0]
  133.         if e.elements('allprop', ns=dav):
  134.             self.allprop=1
  135.             return
  136.         if e.elements('propname', ns=dav):
  137.             self.propname=1
  138.             return
  139.         prop=e.elements('prop', ns=dav)
  140.         if not prop: raise 'Bad Request', 'Invalid xml request.'
  141.         prop=prop[0]
  142.         for val in prop.elements():
  143.             self.propnames.append((val.name(), val.namespace()))
  144.         if (not self.allprop) and (not self.propname) and \
  145.            (not self.propnames):
  146.             raise 'Bad Request', 'Invalid xml request.'
  147.         return
  148.  
  149.     def apply(self, obj, url=None, depth=0, result=None, top=1):
  150.         if result is None:
  151.             result=StringIO()
  152.             depth=self.depth
  153.             url=urlfix(self.request['URL'], 'PROPFIND')
  154.             url=urlbase(url)
  155.             result.write('<?xml version="1.0" encoding="utf-8"?>\n' \
  156.                          '<d:multistatus xmlns:d="DAV:">\n')
  157.         iscol=hasattr(obj, '__dav_collection__')
  158.         if iscol and url[-1] != '/': url=url+'/'
  159.         result.write('<d:response>\n<d:href>%s</d:href>\n' % quote(url))
  160.         if hasattr(aq_base(obj), 'propertysheets'):
  161.             propsets=obj.propertysheets.values()
  162.             obsheets=obj.propertysheets
  163.         else:
  164.             davprops=DAVProps(obj)
  165.             propsets=(davprops,)
  166.             obsheets={'DAV:': davprops}
  167.         if self.allprop:
  168.             stats=[]
  169.             for ps in propsets:
  170.                 if hasattr(aq_base(ps), 'dav__allprop'):
  171.                     stats.append(ps.dav__allprop())
  172.             stats=string.join(stats, '') or '<d:status>200 OK</d:status>\n'
  173.             result.write(stats)            
  174.         elif self.propname:
  175.             stats=[]
  176.             for ps in propsets:
  177.                 if hasattr(aq_base(ps), 'dav__propnames'):
  178.                     stats.append(ps.dav__propnames())
  179.             stats=string.join(stats, '') or '<d:status>200 OK</d:status>\n'
  180.             result.write(stats)
  181.         elif self.propnames:
  182.             rdict={}
  183.             for name, ns in self.propnames:
  184.                 ps=obsheets.get(ns, None)
  185.                 if ps is not None and hasattr(aq_base(ps), 'dav__propstat'):
  186.                     stat=ps.dav__propstat(name, rdict)
  187.                 else:
  188.                     prop='<n:%s xmlns:n="%s"/>' % (name, ns)
  189.                     code='404 Not Found'
  190.                     if not rdict.has_key(code):
  191.                         rdict[code]=[prop]
  192.                     else: rdict[code].append(prop)
  193.             keys=rdict.keys()
  194.             keys.sort()
  195.             for key in keys:
  196.                 result.write('<d:propstat>\n' \
  197.                              '  <d:prop>\n' \
  198.                              )
  199.                 map(result.write, rdict[key])
  200.                 result.write('  </d:prop>\n' \
  201.                              '  <d:status>HTTP/1.1 %s</d:status>\n' \
  202.                              '</d:propstat>\n' % key
  203.                              )
  204.         else: raise 'Bad Request', 'Invalid request'
  205.         result.write('</d:response>\n')        
  206.         if depth in ('1', 'infinity') and iscol:
  207.             for ob in obj.objectValues():
  208.                 dflag=hasattr(ob, '_p_changed') and (ob._p_changed == None)
  209.                 if hasattr(ob, '__dav_resource__'):
  210.                     uri=os.path.join(url, absattr(ob.id))
  211.                     depth=depth=='infinity' and depth or 0
  212.                     self.apply(ob, uri, depth, result, top=0)
  213.                     if dflag: ob._p_deactivate()
  214.         if not top: return result
  215.         result.write('</d:multistatus>')
  216.         return result.getvalue()
  217.  
  218.  
  219.  
  220. class PropPatch:
  221.     """Model a PROPPATCH request."""
  222.     def __init__(self, request):
  223.         self.request=request
  224.         self.values=[]
  225.         self.parse(request)
  226.  
  227.     def parse(self, request, dav='DAV:'):
  228.         body=request.get('BODY', '')
  229.         try:    root=XmlParser().parse(body)
  230.         except: raise 'Bad Request', sys.exc_info()[1]
  231.         vals=self.values
  232.         e=root.elements('propertyupdate', ns=dav)
  233.         if not e: raise 'Bad Request', 'Invalid xml request.'
  234.         e=e[0]
  235.         for ob in e.elements():
  236.             if ob.name()=='set' and ob.namespace()==dav:
  237.                 proptag=ob.elements('prop', ns=dav)
  238.                 if not proptag: raise 'Bad Request', 'Invalid xml request.'
  239.                 proptag=proptag[0]
  240.                 for prop in proptag.elements():
  241.                     # We have to ensure that all tag attrs (including
  242.                     # an xmlns attr for all xml namespaces used by the
  243.                     # element and its children) are saved, per rfc2518.
  244.                     name, ns=prop.name(), prop.namespace()
  245.                     e, attrs=prop.elements(), prop.attrs()
  246.                     if (not e) and (not attrs):
  247.                         # simple property
  248.                         item=(name, ns, prop.strval(), {})
  249.                         vals.append(item)
  250.                     else:
  251.                         # xml property
  252.                         attrs={}
  253.                         prop.remap({ns:'n'})
  254.                         prop.del_attr('xmlns:n')
  255.                         for attr in prop.attrs():
  256.                             attrs[attr.qname()]=attr.value()
  257.                         md={'__xml_attrs__':attrs}
  258.                         item=(name, ns, prop.strval(), md)
  259.                         vals.append(item)
  260.             if ob.name()=='remove' and ob.namespace()==dav:
  261.                 proptag=ob.elements('prop', ns=dav)
  262.                 if not proptag: raise 'Bad Request', 'Invalid xml request.'
  263.                 proptag=proptag[0]
  264.                 for prop in proptag.elements():
  265.                     item=(prop.name(), prop.namespace())
  266.                     vals.append(item)
  267.  
  268.     def apply(self, obj):
  269.         url=urlfix(self.request['URL'], 'PROPPATCH')
  270.         if hasattr(obj, '__dav_collection__'):
  271.             url=url+'/'
  272.         result=StringIO()
  273.         errors=[]
  274.         result.write('<?xml version="1.0" encoding="utf-8"?>\n' \
  275.                      '<d:multistatus xmlns:d="DAV:">\n' \
  276.                      '<d:response>\n' \
  277.                      '<d:href>%s</d:href>\n' % quote(url))
  278.         propsets=obj.propertysheets
  279.         for value in self.values:
  280.             status='200 OK'
  281.             if len(value) > 2:
  282.                 name, ns, val, md=value
  283.                 propset=propsets.get(ns, None)
  284.                 if propset is None:
  285.                     propsets.manage_addPropertySheet('', ns)
  286.                     propset=propsets.get(ns)
  287.                 propdict=propset._propdict()
  288.                 if propset.hasProperty(name):
  289.                     try: propset._updateProperty(name, val, meta=md)
  290.                     except:
  291.                         errors.append(str(sys.exc_info()[1]))
  292.                         status='409 Conflict'
  293.                 else:
  294.                     try: propset._setProperty(name, val, meta=md)
  295.                     except:
  296.                         errors.append(str(sys.exc_info()[1]))
  297.                         status='409 Conflict'
  298.             else:
  299.                 name, ns=value
  300.                 propset=propsets.get(ns, None)
  301.                 if propset is None or not propset.hasProperty(name):
  302.                     errors.append('Property not found: %s' % name)
  303.                     status='404 Not Found'
  304.                 else:
  305.                     try: propset._delProperty(name)
  306.                     except:
  307.                         errors.append('%s cannot be deleted.' % name)
  308.                         status='409 Conflict'
  309.             if result != '200 OK': abort=1
  310.             result.write('<d:propstat xmlns:n="%s">\n' \
  311.                          '  <d:prop>\n' \
  312.                          '  <n:%s/>\n' \
  313.                          '  </d:prop>\n' \
  314.                          '  <d:status>HTTP/1.1 %s</d:status>\n' \
  315.                          '</d:propstat>\n' % (ns, name, status))
  316.         errmsg=string.join(errors, '\n') or 'The operation succeded.'
  317.         result.write('<d:responsedescription>\n' \
  318.                      '%s\n' \
  319.                      '</d:responsedescription>\n' \
  320.                      '</d:response>\n' \
  321.                      '</d:multistatus>' % errmsg)
  322.         result=result.getvalue()
  323.         if not errors: return result
  324.         # This is lame, but I cant find a way to keep ZPublisher
  325.         # from sticking a traceback into my xml response :(
  326.         get_transaction().abort()
  327.         result=string.replace(result, '200 OK', '424 Failed Dependency')
  328.         return result
  329.  
  330.  
  331.  
  332.  
  333.  
  334. class Lock:
  335.     """Model a LOCK request."""
  336.     def __init__(self, request):
  337.         self.request=request
  338.         data=request.get('BODY', '')
  339.         self.scope='exclusive'
  340.         self.type='write'
  341.         self.owner=''
  342.         self.parse(data)
  343.  
  344.     def parse(self, data, dav='DAV:'):
  345.         root=XmlParser().parse(data)
  346.         info=root.elements('lockinfo', ns=dav)[0]
  347.         ls=info.elements('lockscope', ns=dav)[0]
  348.         self.scope=ls.elements()[0].name()
  349.         lt=info.elements('locktype', ns=dav)[0]
  350.         self.type=lt.elements()[0].name()
  351.         lo=info.elements('owner', ns=dav)
  352.         if lo: self.owner=lo[0].toxml()
  353.  
  354.  
  355.  
  356.  
  357.